package com.framework.middleware.kafka;

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

/**
 * @author chaolong.jin
 * @description
 * @date 2019/08/08 19:03
 */
public class ClientConnection {

    public static Properties loadProp(String name) {
        Provider provider = new Provider();
        InputStream inputStream = provider.getClass().getClassLoader().getResourceAsStream(name);
        Properties props = new Properties();
        try {
            props.load(inputStream);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return props;
    }
}
